package com.example.rxjavacoredemo.rxjava;

public interface Observer<T> {

    // 订阅成功
   void onSubscribe(Disposable d);

   void onNext(T t);

   void onError(Throwable throwable);

   void onComplete();
}
